/*
 * 文件名：JMSSourceConfiguration.java
 * 版权：亚信联创版权所有
 * 描述：TODO
 * 修改人：napo
 * 修改时间：2014-12-15
 * 修改内容：TODO
 */
package com.ailk.bigdata.etl.realstream.server.protocal.realmq;

/**
 * @description TODO
 * @author [xuwei3]
 * @version [版本号,2014-12-15]
 * @see [相关类/方法]
 * @since [产品/模块版本]
 */
public class JMSSourceConfiguration
{
	// jms配置信息
	public static final String INITIAL_CONTEXT_FACTORY = "initialContextFactory";
	public static final String INITIAL_CONTEXT_FACTORY_DEFAULT = "org.apache.activemq.jndi.ActiveMQInitialContextFactory";
	public static final String CONNECTION_FACTORY = "connectionFactory";
	public static final String CONNECTION_FACTORY_DEFAULT = "jms/ConnectionFactory";
	public static final String PROVIDER_URL = "providerURL";
	public static final String DESTINATION_NAME = "destinationName";
	public static final String DESTINATION_TYPE = "destinationType";
	public static final String DESTINATION_LOCATOR = "destinationLocator";
	public static final String DESTINATION_LOCATOR_DEFAULT = "CDI";
	public static final String DESTINATION_TYPE_QUEUE = "queue";
	public static final String DESTINATION_TYPE_TOPIC = "topic";
	public static final String MESSAGE_SELECTOR = "messageSelector";
	public static final String USERNAME = "userName";
	public static final String PASSWORD = "userpasswd";
	public static final String BATCH_SIZE = "batchSize";
	public static final int BATCH_SIZE_DEFAULT = 10000;
	public static final String ERROR_THRESHOLD = "errorThreshold";
	public static final int ERROR_THRESHOLD_DEFAULT = 10;
	public static final String POLL_TIMEOUT = "pollTimeout";
	public static final long POLL_TIMEOUT_DEFAULT = 1000L;
	public static final String CONVERTER = "converter";
	public static final String CONVERTER_TYPE = CONVERTER + ".type";
	public static final String CONVERTER_TYPE_DEFAULT = "DEFAULT";
	public static final String CONVERTER_CHARSET = CONVERTER + ".charset";
	public static final String CONVERTER_CHARSET_DEFAULT = "UTF-8";

	// kafka配置信息
	public static final String KAFKA_TOPIC_NAME = "topicName";
	public static final String KAFKA_NUMS_PATITION = "num.partitions";
	public static final String KAFKA_ZOOKEEPER_CONNECT = "zookeeper.connect";
	public static final String KAFKA_CONSUMER_GROUP_ID = "group.id";
	public static final String KAFKA_CONSUMER_INTERFACE_TYPE = "interface.type";
}
